package com.shujia.custom.udf;

import org.apache.hadoop.hive.ql.exec.UDF;
import redis.clients.jedis.Jedis;

public class MyUDFDemo1 extends UDF {
    //需要实现evaluate方法，这个方法将来是集群中调用所识别的方法
    //需求：传入一个字符串 --> $+字符串+#
    public String evaluate(String s) {
        Jedis jedis = new Jedis("192.168.21.150", 7000);
        String s1 = jedis.get(s);
        jedis.close();
        return s1;
    }

    public int evaluate(int num) {
        return num += 1000;
    }

}
